from x_com import xport_core
from x_com.import_api import ecommerce_data_source_service_0_0_1
# ProductSale
async def product_sale(ctx: xport_core.Context, param: ecommerce_data_source_service_0_0_1.ProductSaleInfo):
  SERVICE.product_sale_data_analyzer.data_in(param)

# UserRegister
async def user_register(ctx: xport_core.Context, param: ecommerce_data_source_service_0_0_1.UserInfo):
  SERVICE.user_register_data_analyzer.data_in(param)

# UserLogin
async def user_login(ctx: xport_core.Context, param: ecommerce_data_source_service_0_0_1.UserLoginInfo):
  SERVICE.user_login_data_analyzer.data_in(param)

